package listen

import (
	"context"
	"mrshen_rocket_comsumer/internal/config"
	"mrshen_rocket_comsumer/internal/logic"
	"mrshen_rocket_comsumer/internal/svc"
)

func StartRocketConsumer(svc *svc.ServiceContext, cxt context.Context, c config.Config) {
	// 启动queue服务
	l := logic.NewHelloRocketConsumer(svc, cxt, c)
	_ = l.HelloRocketConsumer()
}
